export default class SocketService {
  // 单例

  static instance = null;
  static get Instance() {
    if (!this.instance) {
      this.instance = new SocketService()
    }
    return this.instance
  }

  // 与服务器连接的实例对象
  ws = null;
  // 存储回调函数的对象
  callBackMapping = {};
  // 标识，是否连接成功
  connected = false;
  // 记录连接失败重试的次数
  sendRetryConut = 0;

  connectRetryCount = 0;

  // 连接服务器的方法
  connect() {
    // 连接服务器
    if (!window.WebSocket) {
      return console.log("浏览器不支持WebSocket")
    }
    this.ws = new WebSocket("ws://localhost:9998");

    // 连接成功的事件
    this.ws.onopen = () => {
      console.log("连接服务器成功了")
      this.connected = true;
      // 重置重新连接次数的变量
      this.connectRetryCount = 0;
    }
    // 1. 连接服务端失败
    // 2. 当连接成功之后，服务器关闭的情况
    this.ws.onclose = () => {
      console.log("连接服务器失败了")
      this.connected = false;
      this.connectRetryCount++
      setTimeout(() => {
        this.connect();
      }, this.connectRetryCount * 500);
    }
    // 得到服务器发送过来的数据
    this.ws.onmessage = msg => {
      // console.log("从服务器端获取数据了")
      // console.log(msg.data);
      const recvData = JSON.parse(msg.data);
      const socketType = recvData.socketType;
      // 判断回调函数是否存在
      if (this.callBackMapping[socketType]) {
        const action = recvData.action;
        if (action === 'getData') {
          const realData = JSON.parse(recvData.data);
          this.callBackMapping[socketType].call(this, realData);
        } else if (action === 'fullScreen') {

        } else if (action === 'themeChange') {

        }
      }
    }
  }

  // 回调函数的注册
  registerCallBack(socketType, callBack) {
    this.callBackMapping[socketType] = callBack;
  }

  //  取消某一个回调函数
  unRegisterCallBack(socketType) {
    this.callBackMapping[socketType] = null;
  }

  send(data) {
    // 判断此时此刻是否连接成功
    if (this.connected) {
      this.sendRetryConut = 0;
      this.ws.send(JSON.stringify(data));
    } else {
      this.sendRetryConut++
      setTimeout(() => {
        this.send(data);
      }, this.sendRetryConut * 500)
    }
  }
}